package com.yujiahao;

import org.apache.flink.kinesis.shaded.com.amazonaws.services.kinesis.clientlibrary.interfaces.v2.IRecordProcessor;
import org.apache.flink.kinesis.shaded.com.amazonaws.services.kinesis.clientlibrary.interfaces.v2.IRecordProcessorFactory;

/**
 * @Description:
 * @Author: yujiahao
 * @Date: 2023/8/2 17:49
 * @Version: 1.0
 */

public class ConsumerRecordProcessorFactory implements IRecordProcessorFactory {
    @Override
    public IRecordProcessor createProcessor() {
        return new KinesisConsumeIRecordProcessorV2();
    }
}
